package com.example.rxjavacoredemo.rxjava.function;

import com.example.rxjavacoredemo.rxjava.Observable;
import com.example.rxjavacoredemo.rxjava.ObservableSource;

public abstract class AbstractObservableWithUpstream<T, U> extends Observable<U> {

    protected final ObservableSource<T> source;

    public AbstractObservableWithUpstream(ObservableSource<T> source) {
        this.source = source;
    }
}
